package com.qin.common;

import org.springframework.stereotype.Component;
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;

@Component
@ServerEndpoint("/websocket")
public class WebSocket {

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("【open】client" + session.getId());
//        try {
//            session.getBasicRemote().sendText("hello client...");
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose(Session session) {
        System.out.println("【close】client" + session.getId());
    }

    /**
     * 收到客户端消息后调用的方法
     */
    @OnMessage
    public void onMessage(Session session, String message) {
        try {
            session.getBasicRemote().sendText("client"+session.getId()+"say:"+message);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 向当前客户端发送消息
     *
     */
    public void sendMessage(Session session, String message) {

    }

}
